﻿<h1><code>sync/atomic</code>标准库包中提供的原子操作</h1>

<p>
原子操作是比其它同步技术更基础的操作。原子操作是无锁的，常常直接通过CPU指令直接实现。
事实上，其它同步技术的实现常常依赖于原子操作。
</p>

<p>
注意，本文中的很多例子并非并发程序。它们只是用来演示如何使用<code>sync/atomic</code>标准库包中提供的原子操作。
</p>

<a class="anchor" id="overview"></a>
<h3>Go 1.19之前的版本中支持的原子操作概述</h3>

<div>
对于一个整数类型<code>T</code>，<code>sync/atomic</code>标准库包提供了下列原子操作函数。
其中<code>T</code>可以是内置<code>int32</code>、<code>int64</code>、<code>uint32</code>、<code>uint64</code>和<code>uintptr</code>类型。

<pre class="line-numbers"><code class="language-go">func AddT(addr *T, delta T)(new T)
func LoadT(addr *T) (val T)
func StoreT(addr *T, val T)
func SwapT(addr *T, new T) (old T)
func CompareAndSwapT(addr *T, old, new T) (swapped bool)
</code></pre>

比如，下列五个原子操作函数提供给了内置<code>int32</code>类型。

<pre class="line-numbers"><code class="language-go">func AddInt32(addr *int32, delta int32)(new int32)
func LoadInt32(addr *int32) (val int32)
func StoreInt32(addr *int32, val int32)
func SwapInt32(addr *int32, new int32) (old int32)
func CompareAndSwapInt32(addr *int32,
				old, new int32) (swapped bool)
</code></pre>

<p>
</p>

下列四个原子操作函数提供给了（安全）指针类型。
因为这几个函数被引入标准库的时候，Go还不支持自定义泛型，所以这些函数是通过<a href="unsafe.html">非类型安全指针</a><code>unsafe.Pointer</code>来实现的。

<pre class="line-numbers"><code class="language-go">func LoadPointer(addr *unsafe.Pointer) (val unsafe.Pointer)
func StorePointer(addr *unsafe.Pointer, val unsafe.Pointer)
func SwapPointer(addr *unsafe.Pointer, new unsafe.Pointer,
				) (old unsafe.Pointer)
func CompareAndSwapPointer(addr *unsafe.Pointer,
				old, new unsafe.Pointer) (swapped bool)
</code></pre>

<p>
因为Go（安全）指针不支持算术运算，所以相对于整数类型，指针类型的原子操作少了一个<code>AddPointer</code>函数。
</p>

<code>sync/atomic</code>标准库包也提供了一个<code>Value</code>类型，以它为基的指针类型<code>*Value</code>拥有四个方法（见下，其中后两个是从Go 1.17开始才支持的）。
<code>Value</code>值用来原子读取和修改任何类型的Go值。

<pre class="line-numbers"><code class="language-go">func (*Value) Load() (x interface{})
func (*Value) Store(x interface{})
func (*Value) Swap(new interface{}) (old interface{})
func (*Value) CompareAndSwap(old, new interface{}) (swapped bool)
</code></pre>

</div>

<a class="anchor" id="overview-1.19"></a>
<h3>Go 1.19+ 版本中新增的原子操作概述</h3>

<div>

<p>
Go 1.19引入了几个各自拥有若干方法的类型用来实现上一节中列出的函数提供的同样的功能。
</p>

<p>
在这些类型中，<code>Int32</code>、<code>Int64</code>、<code>Uint32</code>、<code>Uint64</code>和<code>Uintptr</code>用来实现整数原子操作。
下面列出的是<code>atomic.Int32</code>类型的方法。其它四个类型的方法是类似的。
</p>

<pre class="line-numbers"><code class="language-go">func (*Int32) Add(delta int32) (new int32)
func (*Int32) Load() int32
func (*Int32) Store(val int32)
func (*Int32) Swap(new int32) (old int32)
func (*Int32) CompareAndSwap(old, new int32) (swapped bool)
</code></pre>

<p>
从Go 1.18开始，Go已经开始支持自定义泛型。
从Go 1.19开始，一些标准库包开始使用自定义泛型，这其中包括<code>sync/atomic</code>标准库包。
此包在Go 1.19中引入的<code>atomic.Pointer[T any]</code>类型就是一个泛型类型。
下面列出了它的方法：
</p>

<pre class="line-numbers"><code class="language-go">(*Pointer[T]) Load() *T
(*Pointer[T]) Store(val *T)
(*Pointer[T]) Swap(new *T) (old *T)
(*Pointer[T]) CompareAndSwap(old, new *T) (swapped bool)
</code></pre>

<p>
Go 1.19也引入了一个<code>Bool</code>类型来进行布尔原子操作。
</p>

</div>

<a class="anchor" id="integer"></a>
<h3>整数原子操作</h3>

<div>

<p>
本文的余下部分将通过一些示例来展示如何使用这些原子操作函数。
</p>

下面这个例子展示了如何使用<code>Add</code>原子操作来并发地递增一个<code>int32</code>值。
在此例子中，主协程中创建了1000个新协程。每个新协程将整数<code>n</code>的值增加<code>1</code>。
原子操作保证这1000个新协程之间不会发生数据竞争。此程序肯定打印出<code>1000</code>。

<pre class="line-numbers"><code class="language-go">package main

import (
	"fmt"
	"sync"
	"sync/atomic"
)

func main() {
	var n int32
	var wg sync.WaitGroup
	for i := 0; i < 1000; i++ {
		wg.Add(1)
		go func() {
			atomic.AddInt32(&n, 1)
			wg.Done()
		}()
	}
	wg.Wait()

	fmt.Println(atomic.LoadInt32(&n)) // 1000
}
</code></pre>

<p>
如果我们将新协程中的语句<code>atomic.AddInt32(&amp;n, 1)</code>替换为<code>n++</code>，则最后的输出结果很可能不是<code>1000</code>。
</p>

下面的代码使用Go 1.19引入的<code>atomic.Int32</code>类型和它的方法重新实现了上面的程序。
此实现略显整洁。

<pre class="line-numbers"><code class="language-go">package main

import (
	"fmt"
	"sync"
	"sync/atomic"
)

func main() {
	var n atomic.Int32
	var wg sync.WaitGroup
	for i := 0; i < 1000; i++ {
		wg.Add(1)
		go func() {
			n.Add(1)
			wg.Done()
		}()
	}
	wg.Wait()

	fmt.Println(n.Load()) // 1000
}
</code></pre>

<p>
</p>

<code>StoreT</code>和<code>LoadT</code>原子操作函数或者方法经常被用来需要并发运行的实现setter和getter方法。
下面的例子使用了原子操作函数：

<pre class="line-numbers"><code class="language-go">type Page struct {
	views uint32
}

func (page *Page) SetViews(n uint32) {
	atomic.StoreUint32(&page.views, n)
}

func (page *Page) Views() uint32 {
	return atomic.LoadUint32(&page.views)
}
</code></pre>

下面这个例子使用了Go 1.19引入的类型和方法：

<pre class="line-numbers"><code class="language-go">type Page struct {
	views atomic.Uint32
}

func (page *Page) SetViews(n uint32) {
	page.views.Store(n)
}

func (page *Page) Views() uint32 {
	return page.views.Load()
}
</code></pre>

<p>
</p>

如果<code>T</code>是一个有符号整数类型，比如<code>int32</code>或<code>int64</code>，则<code>AddT</code>函数调用的第二个实参可以是一个负数，用来实现原子减法操作。
但是如果<code>T</code>是一个无符号整数类型，比如<code>uint32</code>、<code>uint64</code>或者<code>uintptr</code>，则<code>AddT</code>函数调用的第二个实参需要为一个非负数，那么如何实现无符号整数类型<code>T</code>值的原子减法操作呢？
毕竟<code>sync/atomic</code>标准库包没有提供<code>SubstractT</code>函数。
根据欲传递的第二个实参的特点，我们可以把<code>T</code>为一个无符号整数类型的情况细分为两类：
<ol>
<li>
	第二个实参为类型为<code>T</code>的一个变量值<code>v</code>。
	因为<code>-v</code>在Go中是合法的，所以<code>-v</code>可以直接被用做<code>AddT</code>调用的第二个实参。
</li>
<li>
	第二个实参为一个正整数常量<code>c</code>，这时<code>-c</code>在Go中是编译不通过的，所以它不能被用做<code>AddT</code>调用的第二个实参。
	这时我们可以使用<code>^T(c-1)</code>（仍为一个正数）做为<code>AddT</code>调用的第二个实参。
</li>
</ol>

<p>
</p>

<p>
此<code>^T(v-1)</code>小技巧对于无符号类型的变量<code>v</code>也是适用的，但是<code>^T(v-1)</code>比<code>T(-v)</code>的效率要低。
</p>

<p>
对于这个<code>^T(c-1)</code>小技巧，如果<code>c</code>是一个类型确定值并且它的类型确实就是<code>T</code>，则它的表示形式可以简化为<code>^(c-1)</code>。
</p>

一个例子：

<pre class="line-numbers"><code class="language-go">package main

import (
	"fmt"
	"sync/atomic"
)

func main() {
	var (
		n uint64 = 97
		m uint64 = 1
		k int    = 2
	)
	const (
		a        = 3
		b uint64 = 4
		c uint32 = 5
		d int    = 6
	)

	show := fmt.Println
	atomic.AddUint64(&n, -m)
	show(n) // 96 (97 - 1)
	atomic.AddUint64(&n, -uint64(k))
	show(n) // 94 (96 - 2)
	atomic.AddUint64(&n, ^uint64(a - 1))
	show(n) // 91 (94 - 3)
	atomic.AddUint64(&n, ^(b - 1))
	show(n) // 87 (91 - 4)
	atomic.AddUint64(&n, ^uint64(c - 1))
	show(n) // 82 (87 - 5)
	atomic.AddUint64(&n, ^uint64(d - 1))
	show(n) // 76 (82 - 6)
	x := b; atomic.AddUint64(&n, -x)
	show(n) // 72 (76 - 4)
	atomic.AddUint64(&n, ^(m - 1))
	show(n) // 71 (72 - 1)
	atomic.AddUint64(&n, ^uint64(k - 1))
	show(n) // 69 (71 - 2)
}
</code></pre>

<p>

</p>

<p>
<code>SwapT</code>函数调用和<code>StoreT</code>函数调用类似，但是返回修改之前的旧值（因此称为置换操作）。
</p>

<p>
一个<code>CompareAndSwapT</code>函数调用传递的旧值和目标值的当前值匹配的情况下才会将目标值改为新值，并返回<code>true</code>；否则立即返回<code>false</code>。
</p>

一个例子：
<pre class="line-numbers"><code class="language-go">package main

import (
	"fmt"
	"sync/atomic"
)

func main() {
	var n int64 = 123
	var old = atomic.SwapInt64(&n, 789)
	fmt.Println(n, old) // 789 123
	swapped := atomic.CompareAndSwapInt64(&n, 123, 456)
	fmt.Println(swapped) // false
	fmt.Println(n)       // 789
	swapped = atomic.CompareAndSwapInt64(&n, 789, 456)
	fmt.Println(swapped) // true
	fmt.Println(n)       // 456
}
</code></pre>

下面是与之对应的使用Go 1.19引入的类型和方法的实现：

<pre class="line-numbers must-line-numbers"><code class="language-go">package main

import (
	"fmt"
	"sync/atomic"
)

func main() {
	var n atomic.Int64
	n.Store(123)
	var old = n.Swap(789)
	fmt.Println(n.Load(), old) // 789 123
	swapped := n.CompareAndSwap(123, 456)
	fmt.Println(swapped)  // false
	fmt.Println(n.Load()) // 789
	swapped = n.CompareAndSwap(789, 456)
	fmt.Println(swapped)  // true
	fmt.Println(n.Load()) // 456
}
</code></pre>

<p>
</p>

<p>
请注意，到目前为止（Go 1.24），一个64位字（int64或uint64值）的原子操作要求此64位字的内存地址必须是8字节对齐的。
对于Go 1.19引入的原子方法操作，此要求无论在32-bit还是64-bit架构上总是会得到满足，但是对于32-bit架构上的原子函数操作，此要求并非总会得到满足。
请阅读<a href="memory-layout.html">关于Go值的内存布局</a>一文获取详情。
</p>

</div>

<a class="anchor" id="pointer"></a>
<h3>指针值的原子操作</h3>

<div>
<p>
上面已经提到了<code>sync/atomic</code>标准库包为指针值的原子操作提供了四个函数，并且指针值的原子操作是通过非类型安全指针来实现的。
</p>

<p>
从<a href="unsafe.html">非类型安全指针</a>一文，我们得知，在Go中，
任何指针类型的值可以被显式转换为非类型安全指针类型<code>unsafe.Pointer</code>，反之亦然。
所以指针类型<code>*unsafe.Pointer</code>的值也可以被显式转换为类型<code>unsafe.Pointer</code>，反之亦然。
</p>

下面这个程序不是一个并发程序。它仅仅展示了如何使用指针原子操作。在这个例子中，类型<code>T</code>可以为任何类型。
<pre class="line-numbers"><code class="language-go">package main

import (
	"fmt"
	"sync/atomic"
	"unsafe"
)

type T struct {x int}

func main() {
	var pT *T
	var unsafePPT = (*unsafe.Pointer)(unsafe.Pointer(&pT))
	var ta, tb = T{1}, T{2}
	// 修改
	atomic.StorePointer(
		unsafePPT, unsafe.Pointer(&ta))
	fmt.Println(pT) // &{1}
	// 读取
	pa1 := (*T)(atomic.LoadPointer(unsafePPT))
	fmt.Println(pa1 == &ta) // true
	// 置换
	pa2 := atomic.SwapPointer(
		unsafePPT, unsafe.Pointer(&tb))
	fmt.Println((*T)(pa2) == &ta) // true
	fmt.Println(pT) // &{2}
	// 比较置换
	b := atomic.CompareAndSwapPointer(
		unsafePPT, pa2, unsafe.Pointer(&tb))
	fmt.Println(b) // false
	b = atomic.CompareAndSwapPointer(
		unsafePPT, unsafe.Pointer(&tb), pa2)
	fmt.Println(b) // true
}
</code></pre>

<p>
是的，目前指针的原子操作使用起来是相当的啰嗦。
事实上，啰嗦还是次要的，更主要的是，因为指针的原子操作需要引入<code>unsafe</code>标准库包，所以这些操作函数不在<a href="https://golang.google.cn/doc/go1compat">Go 1兼容性保证</a>之列。
</p>

<!--
<p>
我个人认为目前支持的这些指针原子操作在今后变为不合法的可能性很小。
即使它们变得不再合法，Go官方工具链中的<code>go fix</code>命令应该会将它们转换为今后的新的合法形式。
但是，这只是我的个人观点，它没有任何权威性。
</p>

<p>
如果你确实担忧这些指针原子操作在未来的合法性，你可以使用下一节将要介绍的原子操作。
但是下一节将要介绍的原子操作对于指针值来说比本节介绍的指针原子操作效率要低得多。
</p>
-->

<p>
与之相对，如果我们使用Go 1.19引入的<code>Pointer</code>泛型类型和它的方法来做指针原子操作，代码将变得简洁的多。
下面的代码证明了这一点。
</p>

<pre class="line-numbers must-line-numbers"><code class="language-go">package main

import (
	"fmt"
	"sync/atomic"
)

type T struct {x int}

func main() {
	var pT atomic.Pointer[T]
	var ta, tb = T{1}, T{2}
	// store
	pT.Store(&ta)
	fmt.Println(pT.Load()) // &{1}
	// load
	pa1 := pT.Load()
	fmt.Println(pa1 == &ta) // true
	// swap
	pa2 := pT.Swap(&tb)
	fmt.Println(pa2 == &ta) // true
	fmt.Println(pT.Load())  // &{2}
	// compare and swap
	b := pT.CompareAndSwap(&ta, &tb)
	fmt.Println(b) // false
	b = pT.CompareAndSwap(&tb, &ta)
	fmt.Println(b) // true
}
</code></pre>

<p>
更为重要的是，上面这段代码没有引入<code>unsafe</code>标准库包，所以Go 1会保证它的向后兼容性。
</p>

</div>

<a class="anchor" id="arbitrary"></a>
<h3>任何类型值的原子操作</h3>

<div>
<p>
<code>sync/atomic</code>标准库包中提供的<code>Value</code>类型可以用来读取和修改任何类型的值。
</p>

<p>
类型<code>*Value</code>有几个方法：<code>Load</code>、<code>Store</code>、<code>Swap</code>和<code>CompareAndSwap</code>（其中后两个方法实在Go 1.17中引入的）。
这些方法均以<code>interface{}</code>做为参数类型，所以传递给它们的实参可以是任何类型的值。
但是对于一个可寻址的<code>Value</code>类型的值<code>v</code>，一旦<code>v.Store</code>方法（<code>(&amp;v).Store</code>的简写形式）被曾经调用一次，则传递给值<code>v</code>的后续方法调用的实参的具体类型必须和传递给它的第一次调用的实参的具体类型一致；
否则，将产生一个恐慌。<code>nil</code>接口类型实参也将导致<code>v.Store()</code>方法调用产生恐慌。
</p>

一个例子：
<pre class="line-numbers"><code class="language-go">package main

import (
	"fmt"
	"sync/atomic"
)

func main() {
	type T struct {a, b, c int}
	var ta = T{1, 2, 3}
	var v atomic.Value
	v.Store(ta)
	var tb = v.Load().(T)
	fmt.Println(tb)       // {1 2 3}
	fmt.Println(ta == tb) // true

	v.Store("hello") // 将导致一个恐慌
}
</code></pre>

另一个例子（针对Go 1.17+）：
<pre class="line-numbers"><code class="language-go">package main

import (
	"fmt"
	"sync/atomic"
)

func main() {
	type T struct {a, b, c int}
	var x = T{1, 2, 3}
	var y = T{4, 5, 6}
	var z = T{7, 8, 9}
	var v atomic.Value
	v.Store(x)
	fmt.Println(v) // {{1 2 3}}
	old := v.Swap(y)
	fmt.Println(v)       // {{4 5 6}}
	fmt.Println(old.(T)) // {1 2 3}
	swapped := v.CompareAndSwap(x, z)
	fmt.Println(swapped, v) // false {{4 5 6}}
	swapped = v.CompareAndSwap(y, z)
	fmt.Println(swapped, v) // true {{7 8 9}}
}
</code></pre>

<p>
事实上，我们也可以使用上一节介绍的指针原子操作来对任何类型的值进行原子读取和修改，不过需要多一级指针的间接引用。
两种方法有各自的好处和缺点。在实践中需要根据具体需要选择合适的方法。
</p>

</div>

<h3>原子操作相关的内存顺序保证</h3>

<p>
详见<a href="memory-model.html#atomic">Go中的内存顺序保证</a>一文对此情况的说明。
</p>

